package com.example.consumer.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import org.springframework.amqp.core.Queue;

@Configuration
public class RabbitConfig {
    public static final String QUEUE_NAME = "viende_queue";

    @Bean  //注入rabbitmq的消费者的队列
    Queue viendeQueue(){
        // args:
        // 1.queue的名字
        // 2.是否持久化（消息队列是否存下来未被消费的消息，若持久化，重启MQ会继续消费）
        // 3.排他性（false）若true，queue只能被创建其的connection处理
        // 4.如果该队列没有消费者，是否自动删除该队列 false
        return new Queue(QUEUE_NAME,true,false,false) ;
    }

}
